package org.osiris.server.engine;

import org.apache.log4j.Logger;



public class Notificador extends Thread {
	
	
	public static ColaNotificaciones colaNotificaciones=new ColaNotificaciones();
	
	Logger logger=Logger.getLogger(this.getClass());
	public Notificador(){
		colaNotificaciones.clear();
	}
	
	public void run()
	{
		while(true){
		while(!colaNotificaciones.isEmpty())
			try{
				colaNotificaciones.poll().notificar();
			}catch(Exception me){
				logger.info("La cola etaba vacia");
			}
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
	public static void main (String [] args) {
        new Notificador().start();
        for(int x=0;x<10;x++){
        	NotificacionInterface notificacion=new EmailNotificacion("asunto "+x,"cuerpo "+x,"cuerpo "+x,"alberto.martinez.mena@gmail.com");
			Notificador.colaNotificaciones.add(notificacion);
        }
        
    }

}
